package org.onion.pattern.sample.active.listener;

import lombok.extern.slf4j.Slf4j;
import org.onion.pattern.event.springboot.rocketmq.annotation.RocketMQConsumerGroup;
import org.onion.pattern.event.springboot.rocketmq.annotation.RocketMQEventListener;
import org.onion.pattern.event.springboot.rocketmq.annotation.enums.ListenerMode;
import org.onion.pattern.sample.active.service.event.ActCrateEventExt;
import org.onion.pattern.sample.active.service.event.FlushCrateEvent;
import org.onion.pattern.sample.active.service.event.MRocketMQMessaage;
import org.springframework.stereotype.Component;

/**
 * tag filter
 * @date 2025-08-23 11:20
 */
@Component
@RocketMQConsumerGroup(value = "TagFilterActiveListener", listenerMode = ListenerMode.Concurrently)
@Slf4j
public class TagFilterActiveListener {

    @RocketMQEventListener(idempotent = false)
    public void on(ActCrateEventExt event) {

        log.info("【收到消息】 TagFilter监听 {}",event);
    }

    @RocketMQEventListener
    public void on(FlushCrateEvent event) {

        log.info("【收到消息】 TagFilter监听 flash {}",event);
    }

    @RocketMQEventListener
    public void on(MRocketMQMessaage event) {

        log.info("【收到消息】  MRocketMQMessaage  {}",event);
    }


}
